31f33cbda2651524e0bae1ab405b29264acd1e68,src/main/java/com/tesco/mewbase/client/impl/ClientImpl.java,ClientImpl,writeQuery,#BsonObject#Consumer#CompletableFuture#,123

Before Change


    private void writeQuery(BsonObject frame, Consumer<QueryResult> resultHandler, CompletableFuture cf) {
        int queryID = nextQueryId.getAndIncrement();
        frame.put(Protocol.QUERY_QUERYID, queryID);
        Buffer buffer = Protocol.encodeFrame(Protocol.QUERY_FRAME, frame);
        queryResultHandlers.put(queryID, resultHandler);
        write(cf, buffer, null);
    }

After Change


        int queryID = requestIDSequence.getAndIncrement();
        frame.put(Protocol.QUERY_QUERYID, queryID);
        queryResultHandlers.put(queryID, resultHandler);
        write(cf, Protocol.QUERY_FRAME, frame);
    }